package com.qf.test;

import com.qf.utils.ESUtil;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RequestOptions;
import org.junit.Test;

import java.io.IOException;

/**
 * 其他查询方式
 */
public class OtherQueryDemo {
    @Test
    public void findById() throws IOException {
        //1. 创建指定的Request对象，并设置索引名称和doc_id
        GetRequest request = new GetRequest();
        request.index("sms-logs-index");
        request.id("31");

        //2. 通过连接对象将Request发送给ES，并接受Response
        GetResponse resp = ESUtil.getClient().get(request, RequestOptions.DEFAULT);

        //3. 通过Response判断添加是否成功
        System.out.println(resp.getSourceAsMap());
    }

}
